from celery import Celery


import os

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 使用下面方法可不写配置文件 config
# celery_app = Celery('meiduo',broker='redis://192.168.217.134/10')

# 创建celery实例
celery_app = Celery('meiduo')
# 加载celery配置
celery_app.config_from_object('celery_tasks.config')

# 自动注册celery任务

celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])

#  测试代码
# @celery_app.task(name='add')
# def add(x, y):
#    return x + y